package repositorio;


import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;

import banco.DB;

/**
 * 
 * @author klebson lou
 * repositorio do usuario
 */
public class RepositorioUsuario {

	/**
	 * metodo para adicionar no repositorio do usuario
	 * 
	 * @param CPF_CNPJ
	 * @param nomeusuario
	 * @param senha
	 * @param tipo
	 * @param endereco
	 * @param email
	 * @param descricao
	 */
	public  void adicionar(String CPF_CNPJ, String nomeusuario, String senha, String tipo, String endereco, String email, String descricao){
		
    try{ 
	  Connection con = DB.getInstance().getConnection();
	  PreparedStatement stmt = con.prepareStatement("insert into usuario (CPF_CNPJ, nomeusuario, senha, tipo, endereco, email, descricao) values (?,?,?,?,?,?,?)");  
		      
        stmt.setString(1, CPF_CNPJ);  
        stmt.setString(2, nomeusuario);  
        stmt.setString(3, senha);  
        stmt.setString(4, tipo);
        stmt.setString(5, endereco);
        stmt.setString(6, email);
        stmt.setString(7, descricao);    
        stmt.execute(); 
        
        stmt.close();  
        DB.getInstance().fecharBanco();
        con.close();  
      
    } catch (Exception e) {  
         e.printStackTrace();  
    }  
		  
	}
	/**
	 * metodo para consultar o usuario no banco
	 * 
	 * @param CPF_CNPJ
	 * @return
	 */
	public  ResultSet consultar(String CPF_CNPJ){
		ResultSet rs = null;
		String sql = "SELECT * FROM usuario where CPF_CNPJ ='" + CPF_CNPJ +"'";
		try{
			Statement stm= DB.getConnections().createStatement();
			rs = stm.executeQuery(sql);
			} 
		catch (Exception e){
			e.printStackTrace();  
		    }

	    return rs;
	}
	/**
	 * metodo para consultar o usuario no banco
	 * 
	 * @param nomeusuario
	 * @return
	 */
	public ResultSet consultarUsuario(String nomeusuario) {
		ResultSet returns = null;
		String sql = "SELECT * FROM usuario where nomeusuario ='" + nomeusuario+ "'";
		try {
			Statement stmdb = DB.getConnections().createStatement();
			returns = stmdb.executeQuery(sql);
		} catch (Exception e) {
			e.printStackTrace();
		}

		return returns;
	}

}